from celery import Celery

# tasks--》broker--》worker

# 第一步创建实例对象和生成任务

# 第二步 通过celery的配置文件设置broker
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'mall.settings'
# 第三步 让celery自动检测任务

# 创建celery实例对象
# 参数main ：一般设置脚本名
app = Celery('celery_tasks')

# 参数文件的路径
app.config_from_object('celery_tasks.config')

# 自动检测任务
# 参数[]
# 每一想就是对应的celery_tasks.sms
app.autodiscover_tasks(['celery_tasks.sms'])

# worker 的执行实在虚拟环境通过命令等待broker分配任务
# celery -A 脚本路径.celery实例对象的文件 worker -l info
# celery -A celery_tasks.main worker -l info